package com.lxt.cloud.teststream.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

//@FunctionalInterface
public interface ReceiveInputChannel {
    // 这里可以定义不同的通道
    String MSG_RECEIVER = "input2"; // 通道名

    @Input(ReceiveInputChannel.MSG_RECEIVER)
    SubscribableChannel msgReceiver();

}
